package cn.net.gemai.springboot_activemq.controller;

import org.springframework.jms.annotation.JmsListener;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class StoreController {
    /**
     * 库存系统从MQ中获取消息更新库存
     * 点对点模式，用JmsListener 监听名称对应的队列消息
     */
    @JmsListener(destination = "库存队列1")
    public void updateStore(String message) {
        System.out.println("JmsListener:" + message);

        /**
         * 监听之后得到结果，执行相应的业务逻辑
         */
    }

    /**
     * 发布/订阅模式接收消息
     * 需要写配置类ActivemqConfig,topicListenerContainer方法
     */
    @JmsListener(destination = "库存通知1", containerFactory = "topicListenerContainer")
    public void updateStore2(String message) {
        System.out.println("topicListener:" + message);

        /**
         * 监听之后得到结果，执行相应的业务逻辑
         */
    }
}
